|
一、创建切割List工具类
/**
* 集成批量切割处理工具类
*/
public class BatchProcessor {
public void processInBatches(List dataList, Consumer batchProcessor, int batchSize) {
List batch;
for (int i = 0; i
void accept(T t);
}
}
二、实际使用
// 实现具体的推送逻辑
BatchProcessor.Consumer pushBatchToServer = list -> {
try {
// 这里是推送方法
String hdInfo = pushOrder();
}
}catch (Exception e){
log.error("同步推送异常",e);
}
};
new BatchProcessor().processInBatches(pushHdOrderDTOS, pushBatchToServer,10);
三、原理
我们创建了一个BatchProcessor类，其中包含一个processInBatches方法，它接受一个待处理的数据列表和一个批量处理器接口（在这里用Java 8的Consumer接口模拟）。processInBatches方法会遍历列表，并按照指定的批次大小（这里是10）截取子列表，然后调用传入的批量处理器接口对每个子列表执行推送操作。 你需要根据实际场景替换pushBatchToServer中的实现，以完成实际的推送任务
|